package com.chennan.rebbitmq.leading.consumer;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author chennan
 * @createTime 2021年07月08日 17:11:00
 */
public interface MyStreamClient {

    String DATA_TO_RABBITMQ_BOOK_INPUT = "dataToRabbitMQBookInput";

    String DATA_TO_WUZHIQ_INPUT = "wuzqToMessageChannelInput";
    /**
     * 消费rabbitMQ 消息
     *
     * @return
     */
    @Input(DATA_TO_RABBITMQ_BOOK_INPUT)
    SubscribableChannel dataToExcelFastInput();

    @Input(DATA_TO_WUZHIQ_INPUT)
    SubscribableChannel dataToWuziqMessageInput();

}
